package com.peaksport.pkms.leanrtest1.service;

import org.springframework.stereotype.Service;

import com.peaksport.framework.extend.kafka.PKKafkaReceiver;
import com.peaksport.framework.vo.JSONKafkaMsg;

@Service
public class TestKafa2NewReceiver extends PKKafkaReceiver {

	@Override
	public String getGroupId() {
		return "peak";
	}

	@Override
	public String getTopic() {

		return "peak001";
	}

	@Override
	public void doConsumeMsg(JSONKafkaMsg jsonKFMsg) throws Exception {
		System.out.println("==========2=========");
		Object obj = jsonKFMsg.getData();
		System.out.println("消息2" + obj.toString());
	}
}
